package com.xiaotu.spider.xunyi.pipeline;

import java.util.List;
import java.util.stream.Collectors;

import org.springframework.stereotype.Component;

import com.xiaotu.common.model.StarBrandModel;
import com.xiaotu.common.util.Constants;
import com.xiaotu.common.util.DataRedisKeyUtils;
import com.xiaotu.spider.APipeline;

import us.codecraft.webmagic.ResultItems;
import us.codecraft.webmagic.Task;

/**
 * @类名 XunYiPipeline
 * @日期 2017年11月22日
 * @作者 WangYanLong
 * @功能 寻艺pipeline
 */

@Component("XunYiPipeline")
public class XunYiPipeline extends APipeline
{
    @Override
    protected void doProcess(ResultItems resultItems, Task task)
    {
    	List<StarBrandModel> list = resultItems.get(StarBrandModel.class.getName());
        if (list != null && !list.isEmpty())
        {
            String key = DataRedisKeyUtils.getKey(Constants.DataRedisKey.XUNYI_YYYYMMDD);
            cacheHandler.hMSet(key, list.stream().collect(Collectors.toMap
                    (StarBrandModel::getNumber, mov -> mov)));
            cacheHandler.setCacheTimeout(key);
        }
 
    }

}
